// 引入数据库连接对象
let connection = require('./modelConnext');

// 导出数据库模型对象
module.exports = {
    /* 验证该用户名是否已经存在  --  存在即为已被注册 */
    checkUser:(userName,callback) => {
        // 创建sql查询语句
        let sqlStr = "SELECT * FROM users WHERE username = ?;"
        // 执行sql语句
        connection.query( sqlStr,[userName],function (err, results, fields) {
            // 查询失败 --  数据库操作失败
            if (err) return callback(err,null);
            // 查询成功 --  数据库查询操作成功
            callback(null,results);
        });
    },
    /*  数据库添加成功注册用户的信息 */
    addUser: (newUser,callback) => {
        // 创建sql执行语句
        let mysql = "INSERT INTO users SET ?";
        // 执行语句
        connection.query(mysql,newUser,(err,results) => {   
            // 数据库操作失败
            if (err) return callback(err,null);
            // 数据库操作成功
            callback(null,results);
        });
    },
    /* 验证用户登录信息的正确性 -- 密码与用户名 */
    checkLogin : (loginData,callback) => {
        // 创建sql查询语句
        let sqlStr = "SELECT * FROM users WHERE username = ? AND password = ?;"
        // 执行sql语句
        connection.query(sqlStr,[loginData.username,loginData.password],(err,results)=> {
            // 查询失败 ：填写信息有错或执行语句不对
            if (err) return callback(err,null);
            // 查询成功 ：用户未注册(查询结果为空数组)或该用户信息存在
            callback(null,results);
        });
    }
};